package com.github.jiangxch.rpc.transport.exchanger;

import com.github.jiangxch.rpc.transport.Channel;

import java.io.IOException;
import java.util.concurrent.CompletableFuture;

/**
 * @author: jiangxch
 * @date: 2021/2/25 上午3:05
 */
public interface ExchangeChannel extends Channel {
    /**
     *
     * @param message 业务请求数据
     * @return
     */
    CompletableFuture<Object> request(Object message) throws IOException;
}
